google.golang.org/grpc/internal/transport.controlBuffer.put (method)

44 uses

	google.golang.org/grpc/internal/transport (current package)
		controlbuf.go#L348: func (c *controlBuffer) put(it cbItem) error {
		http2_client.go#L1047: 	t.controlBuf.put(&goAway{code: http2.ErrCodeNo, debugData: []byte("client transport shutdown"), closeConn: err})
		http2_client.go#L1106: 	t.controlBuf.put(&incomingGoAway{})
		http2_client.go#L1133: 	if err := t.controlBuf.put(df); err != nil {
		http2_client.go#L1153: 		t.controlBuf.put(&outgoingWindowUpdate{streamID: s.id, increment: w})
		http2_client.go#L1162: 		t.controlBuf.put(&outgoingWindowUpdate{streamID: s.id, increment: w})
		http2_client.go#L1180: 	t.controlBuf.put(&outgoingSettings{
		http2_client.go#L1206: 		t.controlBuf.put(&outgoingWindowUpdate{
		http2_client.go#L1216: 			t.controlBuf.put(&outgoingWindowUpdate{
		http2_client.go#L1222: 		t.controlBuf.put(bdpPing)
		http2_client.go#L1243: 				t.controlBuf.put(&outgoingWindowUpdate{
		http2_client.go#L1254: 				t.controlBuf.put(&outgoingWindowUpdate{s.id, w})
		http2_client.go#L1358: 	t.controlBuf.put(pingAck)
		http2_client.go#L1399: 		defer t.controlBuf.put(&incomingGoAway{}) // Defer as t.mu is currently held.
		http2_client.go#L1464: 	t.controlBuf.put(&incomingWindowUpdate{
		http2_client.go#L1829: 				t.controlBuf.put(p)
		http2_client.go#L1882: 	t.controlBuf.put(&outFlowControlSizeRequest{resp})
		http2_server.go#L387: 		t.controlBuf.put(&cleanupStream{
		http2_server.go#L495: 		t.controlBuf.put(&cleanupStream{
		http2_server.go#L547: 		t.controlBuf.put(&cleanupStream{
		http2_server.go#L628: 	t.controlBuf.put(&registerStream{
		http2_server.go#L659: 					t.controlBuf.put(&cleanupStream{
		http2_server.go#L676: 				t.controlBuf.put(&goAway{
		http2_server.go#L724: 		t.controlBuf.put(&outgoingWindowUpdate{streamID: s.id, increment: w})
		http2_server.go#L734: 		t.controlBuf.put(&outgoingWindowUpdate{streamID: s.id,
		http2_server.go#L750: 	t.controlBuf.put(&outgoingWindowUpdate{
		http2_server.go#L754: 	t.controlBuf.put(&outgoingSettings{
		http2_server.go#L780: 		t.controlBuf.put(&outgoingWindowUpdate{
		http2_server.go#L789: 			t.controlBuf.put(&outgoingWindowUpdate{
		http2_server.go#L794: 		t.controlBuf.put(bdpPing)
		http2_server.go#L813: 				t.controlBuf.put(&outgoingWindowUpdate{s.id, w})
		http2_server.go#L835: 	t.controlBuf.put(&cleanupStream{
		http2_server.go#L890: 	t.controlBuf.put(pingAck)
		http2_server.go#L921: 		t.controlBuf.put(&goAway{code: http2.ErrCodeEnhanceYourCalm, debugData: []byte("too_many_pings"), closeConn: errors.New("got too many pings from the client")})
		http2_server.go#L926: 	t.controlBuf.put(&incomingWindowUpdate{
		http2_server.go#L992: 		t.controlBuf.put(&cleanupStream{
		http2_server.go#L1173: 	if err := t.controlBuf.put(df); err != nil {
		http2_server.go#L1238: 				t.controlBuf.put(closeConnection{})
		http2_server.go#L1261: 				t.controlBuf.put(p)
		http2_server.go#L1348: 	t.controlBuf.put(hdr)
		http2_server.go#L1364: 	t.controlBuf.put(&cleanupStream{
		http2_server.go#L1379: 	t.controlBuf.put(&goAway{code: http2.ErrCodeNo, debugData: []byte(debugData), headsUp: true})
		http2_server.go#L1437: 		t.controlBuf.put(&goAway{code: g.code, debugData: g.debugData})
		http2_server.go#L1467: 	t.controlBuf.put(&outFlowControlSizeRequest{resp})